package com.syf.rocker;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * 监听数据源：(消息队列)
 *      1.读取我们配置文件里面的output
 *      2.然后 发送消息，消息队列:trade_plate_out
 */
public interface Source {


    /**
     * 盘口数据的输出
     * @return
     */
    @Output("mail_out")   //队列名称mail_in 与 配置文件中定义的bingding对应
    MessageChannel mailOut() ;


    /**
     * 盘口数据的输出
     * @return
     */
    @Output("download_out")   //队列名称download_in 与 配置文件中定义的bingding对应
    MessageChannel downloadOut() ;


}
